exports.jionChatRooms = function (req, res) {

    //获取参数信息
    var bodyParams = req.routeInfo.bodyParams;

    //返回结果
    var resultData = {};

    //用来存储临时数据
    var data =  {}

    //任务流创建
    async.waterfall([

        //检查是否存在这个聊天室
        //检查是否存在这个用户
        //检查用户是否是在线状态
        //把用户加入到聊天室
        (cb) => {
            db.field('cr_id').where({
                "cr_room_id" : bodyParams.chatName,
                "cr_is_delete" : 0
            }).select("socket_chat_room",(rs)=>{
                if(rs.length == 0){
                    return RES.errorResponse(res,"不存在此聊天室");
                }
                cb()
            })
        },
        (cb) => {
            db.field('u_id,u_nickname').where({
                "u_username" : bodyParams.userName,
                "u_is_delete" : 0
            }).select("socket_user",(rs)=>{
                data.nickname = rs[0].u_nickname
                if(rs.length == 0){
                    return RES.errorResponse(res,"不存在此用户");
                }
                cb()
            })

        },
        (cb) => {
            socketObj._checkingUserStatus(bodyParams.userName,(isTrue) => {
                if(!isTrue){
                    return RES.errorResponse(res,"添加失败，用户没有连接服务器");
                }
                cb()
            })

        },
        (cb) => {
            data.type  = "chatRoom"
            data.chatName  = bodyParams.chatName
            data.userName  = bodyParams.userName
            socketObj._joinRoom(data,(isTrue) => {
                cb()
            })
        }

    ],()=> {

        //返回最终拼接结果
        RES.successResponse(res,resultData);

    });
    
}